package springboot.activeMQ ;

import org.springframework.jms.annotation.JmsListener ;
import org.springframework.stereotype.Component ;

/**
 * p2p模式消费者
 * @author 80002165 @date 2017年7月13日 上午9:59:01
 */
@Component
public class MsgConsumer_P2P {
    
    /*
     * 因为queue采用的是p2p的通信方式，即使有多个consumer去消费消息，消息也只会给一个消费者消费
     */
    
    @JmsListener(destination = "sample.queue", containerFactory = "jmsListenerContainerQueue")
    public void receiveQueue(String msg) {
        System.out.println("收到的消息为：" + msg) ;
    }
    
    @JmsListener(destination = "sample.queue", containerFactory = "jmsListenerContainerQueue")
    public void receiveQueue2(String msg) {
        System.out.println("第二个用户收到消息：" + msg) ;
    }
}
